package ari.com.messaging.queue;

import ari.com.messaging.message.QueueMessage;

public class QueueMgrImpl implements QueueMgr {
	Queue<QueueMessage> inQueue = new QueueImpl<QueueMessage>();
	Queue<QueueMessage> outQueue = new QueueImpl<QueueMessage>();

	@Override
	public void sendRequest(final QueueMessage message) {
		final String payload = message.getPayload();
		message.setPayload(payload.toUpperCase());
		outQueue.enQueue(message);
	}

	@Override
	public QueueMessage receiveResponse() {
		return outQueue.deQueue();
	}

}
